package com.ww.cheappliers.consumer;

import java.util.Observable;

import com.ww.cheappliers.Message;
import com.ww.cheappliers.receive.MessageReaper;

public abstract class AbstractConsumer implements MessageConsumer {
	public void update(Observable o, Object arg) {
		Message[] msgs = (Message[])arg;
		if(msgs == null || msgs.length <= 0)
			return;
		
		for(Message m : msgs){
			if(m == null)
				continue;
			
			gotMessage((MessageReaper)o, m);
		}
	}
}
